package cn.classg.rabbitmq.callback;

import cn.classg.rabbitmq.mq.CallbackInterface;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.connection.CorrelationData;

/**
 * 回调
 * @author CLASSG
 */
public abstract class AbstractMqCallback<T> implements CallbackInterface<T> {

    /**
     *
     * @param correlationData
     * @param ack
     * @param cause
     * @param t
     */
    @Override
    public abstract void confirm(CorrelationData correlationData, boolean ack, String cause,T t);

    /**
     *
     * @param message
     * @param replyCode
     * @param replyText
     * @param exchange
     * @param routingKey
     */
    @Override
    public abstract void returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey);
}
